//package com.cjh.utils;
//
//import org.springframework.amqp.core.Binding;
//import org.springframework.amqp.core.BindingBuilder;
//import org.springframework.amqp.core.FanoutExchange;
//import org.springframework.amqp.core.Queue;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
///**
// * 生产者配置类-fanout
// */
//@Configuration
//public class FanoutConfig {
//    /**
//     * 声明交换机
//     */
//    @Bean
//    public FanoutExchange fanoutExchange() {
//        FanoutExchange fanoutExchange = new FanoutExchange("logs");
//        return fanoutExchange;
//    }
//
//    /**
//     * 声明队列
//     */
//    @Bean
//    public Queue fanoutQueue1() {
//        Queue queue = new Queue("fanout_queue1");
//        return queue;
//    }
//
//    /**
//     * 声明队列
//     */
//    @Bean
//    public Queue fanoutQueue2() {
//        Queue queue = new Queue("fanout_queue2");
//        return queue;
//    }
//    /**
//     *把 fanout_queue1 队列绑定到交换机
//     */
//    @Bean
//    public Binding bindingQ1() {
//        Binding binding = BindingBuilder.bind(fanoutQueue1())
//                .to(fanoutExchange());
//        return binding;
//    }
//
//    /**
//     * 把 fanout_queue2 队列绑定到交换机
//     */
//    @Bean
//    public Binding bindingQ2() {
//        Binding binding = BindingBuilder.bind(fanoutQueue2())
//                .to(fanoutExchange());
//        return binding;
//    }
//}